package com.tengju.bff.interfaces.covercharge.config;


import org.springframework.context.annotation.Configuration;


/**
 *@author liang_shi
 *@date 2020/8/6 11:39
 *@description 初始化MQ队列配置
 */
@Configuration
public class AmqpConfig {

    /**
     * @return 普通队列
     */
//    @Bean
//    public Queue queueAccountBalance() {
//        Map<String, Object> arguments = new HashMap<>(4);
//        return new Queue(MqMessageConstants.SERVICE_MEMBER_PROFIT_SETTLE_NOTIFY, true, false, false, arguments);
//    }
//
//    @Bean
//    public Exchange exchangeAccountBalance() {
//        Map<String, Object> arguments = new HashMap<>(4);
//        return new DirectExchange(MqMessageConstants.SERVICE_MEMBER_PROFIT_SETTLE_NOTIFY, true, false, arguments);
//    }
//
//    @Bean
//    public Binding bindingExchangeAccountBalance() {
//        return BindingBuilder.bind(queueAccountBalance()).to(exchangeAccountBalance()).with(MqMessageConstants.SERVICE_MEMBER_PROFIT_SETTLE_CALLBACK).noargs();
//    }



}